package com.ionehe.group.common.notify.message.producer;


import org.apache.rocketmq.client.producer.MessageQueueSelector;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;

/**
 * Copyright (c) 2021 ionehe.com
 * Date: 2021/4/21
 * Time: 1:22 下午
 *
 * @author 2021年 <a href="mailto:a@ionehe.com">秀</a>
 * 【生产者(顺序消息型)】
 */
public interface OrderProducer {
  void start();
  
  void shutdown();
  
  SendResult send(Message paramMessage, MessageQueueSelector paramMessageQueueSelector, Object paramObject);
  
  boolean isStarted();
  
  boolean isClosed();
}